package com.winglinks.mqttclient;

/**
 * @author wangzhong
 * @description: mqtt客户端接口
 * @date 2024/1/28 14:50
 */
public interface IMyMqttClient {
    /**
     * 发布，默认qos为0，非持久化
     *
     * @param topic       主题名
     * @param pushMessage 消息
     */
    void publish(String topic, String pushMessage);

    /**
     * 发布
     *
     * @param qos
     * @param retained
     * @param topic
     * @param pushMessage
     */
    void publish(int qos, boolean retained, String topic, String pushMessage);

}
